type google.golang.org/grpc/internal/transport.http2Client
40 uses
google.golang.org/grpc/internal/transport (current package)
http2_client.go#L61: type http2Client struct {
http2_client.go#L199: func newHTTP2Client(connectCtx, ctx context.Context, addr resolver.Address, opts ConnectOptions, onClose func(GoAwayReason)) (_ *http2Client, err error) {
http2_client.go#L317: t := &http2Client{
http2_client.go#L461: func (t *http2Client) newStream(ctx context.Context, callHdr *CallHdr) *Stream {
http2_client.go#L498: func (t *http2Client) getPeer() *peer.Peer {
http2_client.go#L505: func (t *http2Client) createHeaderFields(ctx context.Context, callHdr *CallHdr) ([]hpack.HeaderField, error) {
http2_client.go#L609: func (t *http2Client) createAudience(callHdr *CallHdr) string {
http2_client.go#L624: func (t *http2Client) getTrAuthData(ctx context.Context, audience string) (map[string]string, error) {
http2_client.go#L651: func (t *http2Client) getCallAuthData(ctx context.Context, audience string, callHdr *CallHdr) (map[string]string, error) {
http2_client.go#L707: func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr) (*Stream, error) {
http2_client.go#L879: func (t *http2Client) CloseStream(s *Stream, err error) {
http2_client.go#L891: func (t *http2Client) closeStream(s *Stream, err error, rst bool, rstCode http2.ErrCode, st *status.Status, mdata map[string][]string, eosReceived bool) {
http2_client.go#L955: func (t *http2Client) Close(err error) {
http2_client.go#L1012: func (t *http2Client) GracefulClose() {
http2_client.go#L1035: func (t *http2Client) Write(s *Stream, hdr []byte, data []byte, opts *Options) error {
http2_client.go#L1058: func (t *http2Client) getStream(f http2.Frame) *Stream {
http2_client.go#L1068: func (t *http2Client) adjustWindow(s *Stream, n uint32) {
http2_client.go#L1077: func (t *http2Client) updateWindow(s *Stream, n uint32) {
http2_client.go#L1086: func (t *http2Client) updateFlowControl(n uint32) {
http2_client.go#L1107: func (t *http2Client) handleData(f *http2.DataFrame) {
http2_client.go#L1173: func (t *http2Client) handleRSTStream(f *http2.RSTStreamFrame) {
http2_client.go#L1199: func (t *http2Client) handleSettings(f *http2.SettingsFrame, isFirst bool) {
http2_client.go#L1248: func (t *http2Client) handlePing(f *http2.PingFrame) {
http2_client.go#L1261: func (t *http2Client) handleGoAway(f *http2.GoAwayFrame) {
http2_client.go#L1344: func (t *http2Client) setGoAwayReason(f *http2.GoAwayFrame) {
http2_client.go#L1359: func (t *http2Client) GetGoAwayReason() (GoAwayReason, string) {
http2_client.go#L1365: func (t *http2Client) handleWindowUpdate(f *http2.WindowUpdateFrame) {
http2_client.go#L1373: func (t *http2Client) operateHeaders(frame *http2.MetaHeadersFrame) {
http2_client.go#L1566: func (t *http2Client) readServerPreface() error {
http2_client.go#L1582: func (t *http2Client) reader(errCh chan<- error) {
http2_client.go#L1659: func (t *http2Client) keepalive() {
http2_client.go#L1737: func (t *http2Client) Error() <-chan struct{} {
http2_client.go#L1741: func (t *http2Client) GoAway() <-chan struct{} {
http2_client.go#L1745: func (t *http2Client) ChannelzMetric() *channelz.SocketInternalMetric {
http2_client.go#L1769: func (t *http2Client) RemoteAddr() net.Addr { return t.remoteAddr }
http2_client.go#L1771: func (t *http2Client) IncrMsgSent() {
http2_client.go#L1776: func (t *http2Client) IncrMsgRecv() {
http2_client.go#L1781: func (t *http2Client) getOutFlowWindow() int64 {
http2_client.go#L1796: func (t *http2Client) stateForTesting() transportState {
transport.go#L246: ct *http2Client // nil for server side Stream